package cn.sirun.com.fca.personal.center.loader;

import com.tencent.cloud.iov.kernel.model.BaseResponse;

import cn.sirun.com.fca.personal.center.model.request.MessageRequest;
import cn.sirun.com.fca.personal.center.model.response.MessageResponse;
import cn.sirun.com.fca.personal.center.repo.MessageRepository;
import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class MessageLoader extends MessageFlowLoader {

    public Observable<BaseResponse<MessageResponse>> getMessageList(MessageRequest request) {
        return MessageRepository.getInstance().getMessageList(request)
                .subscribeOn(Schedulers.io());
    }


}
